package com.sqllog.listener;


import com.sqllog.entity.RowChangeInfo;

/**
 * canal 的事件接口层（表数据改变）
 *
 * @author chennengcheng
 * @date 2020-08-24 17:36
 * @remark
 */

public interface CanalEventListener {


    /**
     * 处理事件
     */
    void onEvent(RowChangeInfo rowChangeInfo);

    /**
     * 异常回调处理方法
     * @param rowChangeInfo
     * @param e
     */
    void callBackForException(RowChangeInfo rowChangeInfo, Exception e);
}
